/***
 *   @title qz
 *   @description <description class purpose>
 *   @author yichen
 *   @version 1.0.0
 *   @create 2023/10/24 0024
 **/
package io.gitee.wokaixin.yunque.driver;

import lombok.*;

@Data
public class KafkaConfig {
    public KafkaConfig() {
        this.brokerList = "127.0.0.1:9092";
        this.topic = "message";
        this.produceInterval = 1000;
    }

    protected String brokerList;
    protected String topic;
    protected int produceInterval;
}
